/**
 * Copyright 2019 Inc.
 **/
package com.myz.rabbitmqspring.spring.consume;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;

import java.io.IOException;

/**
 * @author maoyz0621 on 19-4-16
 * @version: v1.0
 */
public class BaseMessage {

    /**
     * @param message
     * @param channel
     * @throws IOException
     */
    protected void success(Message message, Channel channel) throws IOException {
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
    }
}
